plugin/kvm/src/main/java/org/zstack/kvm/KvmVmSyncPingTask.java (2)

319-352: 周期任务资源管理问题

startOrphanedVmCleanupTask() 提交了一个周期任务，但在 stop() 方法（第 415-418 行）中没有取消该任务。这可能导致组件停止后任务仍在运行。

建议保存 PeriodicTask 的引用并在 stop() 中取消：

♻️ 建议的修改

在类中添加字段保存任务引用：

private Future<?> orphanedVmCleanupTaskFuture;

修改 startOrphanedVmCleanupTask 保存返回值：

 private void startOrphanedVmCleanupTask() {
-    thdf.submitPeriodicTask(new PeriodicTask() {
+    orphanedVmCleanupTaskFuture = thdf.submitPeriodicTask(new PeriodicTask() {
         // ... existing code
     });
 }

修改 stop() 方法取消任务：

 `@Override`
 public boolean stop() {
+    if (orphanedVmCleanupTaskFuture != null) {
+        orphanedVmCleanupTaskFuture.cancel(false);
+    }
     return true;
 }

---

328-328: 建议提取魔法数字为常量

周期任务的间隔 60 秒直接硬编码在代码中。建议提取为类常量或考虑使其可配置，以便于维护和调整。

♻️ 建议的修改

+private static final long ORPHANED_VM_CLEANUP_INTERVAL_SECONDS = 60;
+
 private void startOrphanedVmCleanupTask() {
     thdf.submitPeriodicTask(new PeriodicTask() {
         // ...
         `@Override`
         public long getInterval() {
-            return 60; // Check every 60 seconds
+            return ORPHANED_VM_CLEANUP_INTERVAL_SECONDS;
         }
         // ...
     });
 }

plugin/kvm/src/main/java/org/zstack/kvm/KvmVmSyncPingTask.java (1)

517-523: 建议：使用 CAS 移除以保持一致性

与 isVmDoNotNeedToTrace 类似，迭代器移除不保证原子性。虽然影响较小，但为保持一致性，建议使用 remove(key, expectedValue)：

♻️ 可选改进

         while (it.hasNext()) {
             Map.Entry<String, Long> entry = it.next();
             if (now - entry.getValue() >= ORPHAN_TTL_MS) {
-                it.remove();
+                orphanedSkipVms.remove(entry.getKey(), entry.getValue());
                 logger.info(String.format("cleaned up expired orphaned skip entry for VM[uuid:%s]", entry.getKey()));
             }
         }

compute/src/main/java/org/zstack/compute/vm/VmInstanceBase.java (1)

8476-8496: 建议捕获 hostUuid 本地变量以避免并发下日志/目标不一致
当前回调里使用 self.getHostUuid()，若宿主在异步期间变化，日志与目标可能不一致。

♻️ 可选改进（保持语义不变）

 private void syncVmDevicesAddressInfo(String vmUuid) {
-    if (self.getHostUuid() == null) {
+    String hostUuid = self.getHostUuid();
+    if (hostUuid == null) {
         return;
     }
     SyncVmDeviceInfoMsg msg = new SyncVmDeviceInfoMsg();
     msg.setVmInstanceUuid(vmUuid);
-    msg.setHostUuid(self.getHostUuid());
-    bus.makeTargetServiceIdByResourceUuid(msg, HostConstant.SERVICE_ID, msg.getHostUuid());
+    msg.setHostUuid(hostUuid);
+    bus.makeTargetServiceIdByResourceUuid(msg, HostConstant.SERVICE_ID, hostUuid);
     bus.send(msg, new CloudBusCallBack(msg) {
         `@Override`
         public void run(MessageReply reply) {
             if (!reply.isSuccess()) {
                 logger.warn(String.format("Failed to sync vm device info for vm[uuid:%s], %s",
                     vmUuid, reply.getError()));
             } else {
                 logger.debug(String.format("Sent SyncVmDeviceInfoMsg for vm[uuid:%s] on host[uuid:%s]",
-                    vmUuid, self.getHostUuid()));
+                    vmUuid, hostUuid));
             }
         }
     });
 }